package com.atbeijing.bigdata.spark.core.rdd.part

import org.apache.spark.{SparkConf, SparkContext}

object Spark03_RDD_IO_Load {

    def main(args: Array[String]): Unit = {
        val conf = new SparkConf().setMaster("local").setAppName("Partitioner")
        val sc = new SparkContext(conf)

        println(sc.textFile("output1").collect().mkString(","))
        println(sc.objectFile[(String, String)]("output2").collect().mkString(","))
        println(sc.sequenceFile[String, String]("output3").collect().mkString(","))
        sc.stop()
    }
}
